package com.greedy.service;

import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import com.greedy.bean.dto.LoginFormDTO;
import com.greedy.bean.dto.UserDTO;
import com.greedy.bean.pojo.User;
import com.greedy.bean.pojo.UserInfo;
import com.greedy.interceptor.UserHolder;
import com.greedy.utils.RegexUtils;
import com.greedy.utils.Result;
import com.greedy.utils.ValidateCodeUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.n3r.eql.Eql;
import org.springframework.beans.BeanUtils;
import org.springframework.data.redis.connection.BitFieldSubCommands;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpSession;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.List;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

import static com.greedy.constants.CommentConstants.*;

/**
 * @Author: Yanxy
 * @Date: Created in:2022-12-24
 * Description: 用户
 */
@Slf4j
@Service
public class UserService {

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    /**
     * 发送短信验证码
     *
     * @param phone 手机号
     * @return 成功/失败
     */
    public Result sendCode(String phone) {
        // 校验手机号格式
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手机号格式无效");
        }
        // 手机号正确，生成验证码
        Integer code = ValidateCodeUtil.generateValidateCode(CODE_LENGTH);
        // 验证码保存到Redis，有效期2分钟
        stringRedisTemplate.opsForValue().set(LOGIN_CODE_KEY + phone, String.valueOf(code), LOGIN_CODE_TTL, TimeUnit.MINUTES);
        // 条件有限，发送验证码到日志。。。
        log.debug("发送验证码生成，验证码：{}", code);
        return Result.ok();
    }

    /**
     * 用户登录
     *
     * @param loginForm 手机号、验证码、密码
     * @param session   session
     * @return 统一返回
     */
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        String phone = loginForm.getPhone();
        // 校验手机号格式
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手机号格式无效");
        }
        // 校验短信验证码
        String cacheCode = stringRedisTemplate.opsForValue().get(LOGIN_CODE_KEY + phone);
        if (StringUtils.isBlank(cacheCode) || !StringUtils.equals(cacheCode, loginForm.getCode())) {
            return Result.fail("验证码错误");
        }
        // 根据手机号查询用户信息
        User user = new Eql().selectFirst("getUserByPhone").params(phone).returnType(User.class).execute();
        log.info("大白点评-登陆查询用户信息-用户信息为：{}", JSON.toJSONString(user));
        // 如果不存在自动帮其创建
        if (null == user) {
            user = createUserByPhone(phone);
        }
        // 保存用户信息至Redis
        String token = UUID.randomUUID().toString().replaceAll("-", "");
        UserDTO userDTO = new UserDTO();
        BeanUtils.copyProperties(user, userDTO);
        // UserDTO->HashMap
        HashMap<String, String> userMap = JSON.parseObject(JSON.toJSONString(userDTO), new TypeReference<HashMap<String, String>>() {
        });
        String tokenKey = LOGIN_USER_KEY + token;
        stringRedisTemplate.opsForHash().putAll(tokenKey, userMap);
        // 用户信息保存7天
        stringRedisTemplate.expire(tokenKey, LOGIN_USER_TTL, TimeUnit.MINUTES);
        // 返回token
        return Result.ok(token);
    }

    /**
     * 通过手机号创建新用户
     *
     * @param phone 手机号
     * @return 用户信息
     */
    private User createUserByPhone(String phone) {
        User user = new User();
        user.setPhone(phone);
        user.setNickName(USER_NICK_NAME_PREFIX + getRandomString(10));
        Eql eql = new Eql();
        eql.insert("saveUser").params(user).execute();
        Long userId = eql.selectFirst("getUserId").params(phone).returnType(Long.class).execute();
        user.setId(userId);
        log.info("大白点评-创建新用户-用户信息为：{}", JSON.toJSONString(user));
        return user;
    }

    /**
     * 生成指定长度的随机字符串
     *
     * @param length 字符串长度
     * @return 随机字符串
     */
    private String getRandomString(int length) {
        String str = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
        Random random = new Random();
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < length; i++) {
            sb.append(str.charAt(random.nextInt(str.length())));
        }
        return sb.toString();
    }

    public UserInfo info(Long userId) {
        return new Eql().selectFirst("getUserInfo").params(userId).returnType(UserInfo.class).execute();
    }

    public UserDTO getById(Long userId) {
        // 查询详情
        User user = new Eql().selectFirst("getUserById").params(userId).returnType(User.class).execute();
        if (user == null) {
            return null;
        }
        // 返回
        return BeanUtil.copyProperties(user, UserDTO.class);
    }

    public void sign() {
        // 1.获取当前登录用户
        Long userId = UserHolder.getUser().getId();
        // 2.获取日期
        LocalDateTime now = LocalDateTime.now();
        // 3.拼接key
        String keySuffix = now.format(DateTimeFormatter.ofPattern(":yyyyMM"));
        String key = USER_SIGN_KEY + userId + keySuffix;
        // 4.获取今天是本月的第几天
        int dayOfMonth = now.getDayOfMonth();
        // 5.写入Redis SETBIT key offset 1
        stringRedisTemplate.opsForValue().setBit(key, dayOfMonth - 1, true);
    }

    public Integer signCount() {
        // 1.获取当前登录用户
        Long userId = UserHolder.getUser().getId();
        // 2.获取日期
        LocalDateTime now = LocalDateTime.now();
        // 3.拼接key
        String keySuffix = now.format(DateTimeFormatter.ofPattern(":yyyyMM"));
        String key = USER_SIGN_KEY + userId + keySuffix;
        // 4.获取今天是本月的第几天
        int dayOfMonth = now.getDayOfMonth();
        // 5.获取本月截止今天为止的所有的签到记录，返回的是一个十进制的数字 BITFIELD sign:5:202203 GET u14 0
        List<Long> result = stringRedisTemplate.opsForValue().bitField(
                key,
                BitFieldSubCommands.create()
                        .get(BitFieldSubCommands.BitFieldType.unsigned(dayOfMonth)).valueAt(0)
        );
        if (result == null || result.isEmpty()) {
            // 没有任何签到结果
            return 0;
        }
        Long num = result.get(0);
        if (num == null || num == 0) {
            return 0;
        }
        // 6.循环遍历
        int count = 0;
        while (true) {
            // 6.1.让这个数字与1做与运算，得到数字的最后一个bit位  // 判断这个bit位是否为0
            if ((num & 1) == 0) {
                // 如果为0，说明未签到，结束
                break;
            }else {
                // 如果不为0，说明已签到，计数器+1
                count++;
            }
            // 把数字右移一位，抛弃最后一个bit位，继续下一个bit位
            num >>>= 1;
        }
        return count;
    }
}
